package com.xiaoniu.mc.consumer;

import com.xiaoniu.mc.client.annotation.XmqConsumer;
import com.xiaoniu.mc.client.handler.XmqMessageHook;
import com.xiaoniu.mc.client.message.RecieveMessageWrapper;

import java.util.List;

/**
 * @类描述：
 * @创建人：林继丰
 * @创建时间：2017/8/18 15:18
 * @版权：Copyright (c) 深圳市牛鼎丰科技有限公司-版权所有.
 */
@XmqConsumer(topic = "f", tags = "A", groups = "f1", isOrderLy = true, isBroadcast = false, batchConsumerMessage = 100)
public class Consumer2 implements XmqMessageHook {

    @Override
    public void handle(List<RecieveMessageWrapper> messageWrappers) {
        for (RecieveMessageWrapper msg : messageWrappers) {
            System.out.println("s2:" + msg.toString());
        }
    }
}
